package iotcenterinit

import (
	_ "iotall/iotcenter/centerconfig"
	"iotall/iotcenter/server"
)

var (
	//	consumerServer *kafkaserver.ConsumerServer
	onlineserver *server.OnlineServer
)

func Init() {
	//consumerServer = &kafkaserver.ConsumerServer{
	//	Name:    "在线信息接收",
	//	Topic:   entity.EVENTTOPIC,
	//	GroupID: "Online",
	//}
	//consumerServer.Do = consumerServerDo
	//consumerServer.Start()
	onlineserver = &server.OnlineServer{}
	onlineserver.Start()
}
